/**
 * Description:
 * Class Name:UdpServer
 * Date:2022/5/27 11:03
 *
 * @author LTisme
 * @version JAVA17
 */
package 疯狂Java讲义.第17章_网络编程._17_4_基于UDP的网络编程._17_4_2_使用DatagramSocket发送_接收数据;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.nio.charset.StandardCharsets;

public class UdpServer {
    public static final int PORT = 30000;
    // 定义每个数据报的大小最大为4KB
    private static final int DATA_SIZE = 4096;
    // 定义接收网络数据的字节数组
    byte[] inBuff = new byte[DATA_SIZE];
    // 以指定字节数组创建准备接收数据的DatagramPacket对象
    private DatagramPacket inPacket = new DatagramPacket(inBuff, inBuff.length);
    // 有了接收的，还得定义一个发送用的DatagramPacket对象
    private DatagramPacket outPacket;
    // 定义一个字符串数组，服务器端发送该数组的元素
    String[] books = new String[]{
            "three-bodies problem",
            "Crazy Java",
            "Gone with the wind",
            "Alice in Wonderland",
    };

    public void init() throws IOException{
        try (
                // 创建DatagramSocket对象
                var socket = new DatagramSocket(PORT)
                ){
            // 采用循环接收数据
            for (int i = 0; i < 1000; i++) {
                // 读取Socket中的数据，读取到的数据放入inPacket封装的数组里
                socket.receive(inPacket);
                // 判断inPacket.getData()和inBuff是否是同一个数组
                System.out.println("判断inPacket.getData()和inBuff是否是同一个数组:" + (inBuff == inPacket.getData()));
                // 将接收到的内容转换成字符串后输出
                System.out.println(new String(inBuff, 0, inPacket.getLength()));
                // 从字符串数组中取出一个元素作为发送数据
                byte[] sendData = books[i % 4].getBytes(StandardCharsets.UTF_8);
                // 以指定的字节数组作为发送数据，以刚接收到的DatagramPacket的源SocketAddress作为目标SocketAddress创建DatagramPacket
                outPacket = new DatagramPacket(sendData, sendData.length, inPacket.getSocketAddress());
                // 发送数据
                socket.send(outPacket);
            }
        }
    }

    public static void main(String[] args) throws IOException{
        new UdpServer().init();
    }
}
